package com.iot.system.service.impl;

import com.iot.common.utils.RedisUtil;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;

/**
 * @author mayanbin
 * @date 2024/8/21
 * @description TODO
 **/
@Service
public class ListRedisQueue {

    public static final String mqKey = "listQueue";

    //这里消费redis里面 非阻塞的队列
    private void consume () {
        while (true){
            RedisUtil.ListOps.lLeftPop(mqKey);
        }
    }


}
